package com.huangye88.etl.flinkrunner;


import com.huangye88.etl.origin.KafkaToHbaseOrigin;
import org.apache.beam.runners.flink.FlinkPipelineOptions;
import org.apache.beam.runners.flink.FlinkRunner;
import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.options.PipelineOptionsFactory;

/*Kafka to Hbase*/
public class KafkaToHbaseFlink {

    public static void main(String[] args) {
        PipelineOptions pipe = PipelineOptionsFactory.fromArgs(args).as(FlinkPipelineOptions.class);
        pipe.setRunner(FlinkRunner.class);
        Pipeline pipeline = Pipeline.create(pipe);
        KafkaToHbaseOrigin.dealWithPipeline(pipeline);

        pipeline.run().waitUntilFinish();
    }
}
